package com.companyname.projecttemplate.mq;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

import com.base.core.head.ao.WsMessageAO;
import com.companyname.projecttemplate.constants.MqTopicConstants;

/**
 * Ws消息处理
 * @author zywei
 *
 */
@Component
@RocketMQMessageListener(topic = "${mq.ws.service.channel}", consumerGroup = MqTopicConstants.MQ_WS_MESSAGE_WS)
public class WsHandleMessageMqConsumer implements RocketMQListener<WsMessageAO<String>> {
	
	@Override
	public void onMessage(WsMessageAO<String> ao) {
		System.out.println(ao);
	}
}
